package cn.me.alphamq.common.entity.resp;

import cn.me.alphamq.common.entity.BaseMsg;
import cn.me.alphamq.common.model.broker.CommitLogTopicModel;
import cn.me.alphamq.common.model.broker.ConsumeQueueOffsetModel;

import java.util.List;

/**
 * 控制台列举所有 topic 信息的响应
 *
 * @author f
 */
public class ListAllTopicInfoResp extends BaseMsg {

    /**
     * broker 中所有 topic 的模型
     */
    private List<CommitLogTopicModel> commitLogTopicModelList;

    /**
     * broker 中所有消费偏移量的模型
     */
    private ConsumeQueueOffsetModel consumeQueueOffsetModel;

    public ListAllTopicInfoResp() {
    }

    public ListAllTopicInfoResp(String msgId, List<CommitLogTopicModel> commitLogTopicModelList,
                                ConsumeQueueOffsetModel consumeQueueOffsetModel) {
        super(msgId);
        this.commitLogTopicModelList = commitLogTopicModelList;
        this.consumeQueueOffsetModel = consumeQueueOffsetModel;
    }

    public List<CommitLogTopicModel> getCommitLogTopicModelList() {
        return commitLogTopicModelList;
    }

    public void setCommitLogTopicModelList(List<CommitLogTopicModel> commitLogTopicModelList) {
        this.commitLogTopicModelList = commitLogTopicModelList;
    }

    public ConsumeQueueOffsetModel getConsumeQueueOffsetModel() {
        return consumeQueueOffsetModel;
    }

    public void setConsumeQueueOffsetModel(ConsumeQueueOffsetModel consumeQueueOffsetModel) {
        this.consumeQueueOffsetModel = consumeQueueOffsetModel;
    }
}
